//package com.shujia.scala
//
//import scala.actors.Actor
//
//object Demo22Actor {
//  def main(args: Array[String]): Unit = {
//
//    val worker = new Worker
//    val master = new Master(worker)
//
//    worker.start()
//    master.start()
//
//  }
//}
//
///**
//  * 主节点
//  *
//  */
//class Master(_worker: Worker) extends Actor {
//
//  //在master里面保存worket的信息
//  val worker: Actor = _worker
//
//  override def act(): Unit = {
//
//    //发送消息给worker
//    worker ! Message("心跳消息", 1, this)
//
//    while (true) {
//      receive {
//        case s: String => println("master:" + s)
//      }
//    }
//  }
//}
//
///**
//  *
//  * 从节点
//  */
//
//class Worker extends Actor {
//  override def act(): Unit = {
//
//    while (true) {
//      receive {
//        case mes: Message => {
//          println("worker:" + mes)
//
//          //发送消息给master
//          val master = mes.actor
//
//          master ! "心跳信息接受成功"
//
//        }
//      }
//    }
//  }
//}
//
//case class Message(mes: String, code: Int, actor: Actor)